//package com.letoken.platform.repo.wallet.manager;
//
//
//import com.alibaba.fastjson.JSONObject;
//import com.letoken.platform.repo.app.po.AppUserIssue;
//import com.letoken.platform.repo.app.po.AppUserTeam;
//import com.letoken.platform.repo.wallet.constant.AppRabbitConstant;
//import com.letoken.platform.repo.wallet.req.RechargeCallbackReq;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.stereotype.Component;
//
//@Component
//public class AppMQManager {
//
//    public void teamDynamicReward(RabbitTemplate rabbitTemplate, AppUserTeam req, Integer ms) {
//        rabbitTemplate.convertAndSend(
//                AppRabbitConstant.TOPIC_EXCHANGE_USER,
//                AppRabbitConstant.QUEUE_USER_TEAM_DYNAMIC_REWARD,
//                JSONObject.toJSON(req).toString(),
//                message -> {
//                    message.getMessageProperties().setExpiration(ms.toString());
//                    return message;
//                }
//        );
//    }
//}
